package com.thomsonreuters.ce.base.io.queue;


public interface Pipe<T> {
	public T getObj();
	public Object putObj(T newObj);
	public void Shutdown(boolean isNormal);
	public long getInputCount();
	public long getOutputCount();
}
